package com.xiguthings.xiniu.iot.device.state.kafka;

import com.xiguthings.iot.kafka.consumer.Consumer;

public class ConsumerRunnable implements Runnable {
	private Consumer consumer;
	private KafkaClient kafkaClient;

	public ConsumerRunnable(KafkaClient kafkaClient, Consumer consumer) {
		this.consumer = consumer;
		this.kafkaClient = kafkaClient;
	}

	@Override
	public void run() {
		kafkaClient.consumMessage(consumer, 100);
	}

}
